package com.zzy.demo.service.mqtt;

/**
 * MQTT工具类操作
 */
public interface MQTTService {

	/**
	 * 向某个主题发布消息 默认qos：1
	 */
	public void pub(String topic, String msg);

	/**
	 * 向某个主题发布消息
	 *
	 * @param topic: 发布的主题
	 * @param msg:   发布的消息
	 * @param qos:   消息质量 Qos：0、1、2
	 */
	public void pub(String topic, String msg, int qos);
	
	
	
	
	

	/**
	 * 订阅某一个主题 ，此方法默认的的Qos等级为：1
	 *
	 * @param topic 主题
	 */
	public void sub(String topic);

	/**
	 * 订阅某一个主题，可携带Qos
	 *
	 * @param topic 所要订阅的主题
	 * @param qos   消息质量：0、1、2
	 */
	public void sub(String topic, int qos);
	
	
	

	/**
	 * 关闭MQTT连接
	 */
	public void close();

}
